package com.dss.auto_deploy.service;

import com.dss.auto_deploy.domain.AdmMq;
import com.dss.auto_deploy.dto.*;
import com.dss.auto_deploy.vo.AdmMqVo;
import com.baomidou.mybatisplus.extension.service.IService;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import org.springframework.web.multipart.MultipartFile;

import java.util.List;

/**
* @Description:mq消息队列Service
* @author dongshoushan
* @date 2022-11-03 19:24:22
*/
public interface IAdmMqService  extends IService<AdmMq> {
    /**
    * 新增mq消息队列
    * @param admMqAddDto
    * @return
    */
    int insert(AdmMqAddDto admMqAddDto);

    /**
    * 修改mq消息队列
    * @param admMqUpdateDto
    * @return
    */
    int update(AdmMqUpdateDto admMqUpdateDto);

    /**
    * 批量删除mq消息队列
    * @param ids
    * @return
    */
    void deleteBatch(Long[] ids);

    /**
    * mq消息队列查询
    * @param dto
    * @return List<AdmMq>
    */
    Page<AdmMqVo> list(AdmMqPageDto dto) throws InterruptedException;

    List<AdmMqVo> convertToVo(List<AdmMq> records) throws InterruptedException;

    void installRabbitmq(String ids, String tempPath, MultipartFile rabbitmqFile);

}
